let fs = require("fs")

let rs = fs.createReadStream('./1.txt', {
    highWaterMark: 3
})

// rs.on('data', function(data){
//     console.log(data)
// })
// rs.on('end', function(){
//     console.log('end')
// })

/**
 * 切换为flowing模式
 *  监听 'data' 事件
 *  调用 stream.resume() 方法
 *  调用 stream.pipe() 方法将数据发送到Writable
 * 
 */

//当监听readable 事件的时候，会进入暂停模式
rs.on("readable", function(){
    console.log(rs._readableState.length)
    console.log(rs.read(2))
    console.log(rs._readableState.length)
    // console.log(rs.read(1))
    // console.log(rs.read(1))
    
    // 当你读完指定的字节后，如果可读流发现剩下的字节比最高水位线小，会立即读取填充
    setTimeout(function(){
        console.log(rs._readableState.length)
    }, 200)
})



